package com.chb.test.getOddNumDemo_13;

import java.util.concurrent.*;

public class MyThreadPool {
    public static void main(String[] args) {
        // ThreadPoolExecutor pool = new ThreadPoolExecutor();
        /*
           参数1：核心线程数量           不能小于0
           参数2：最大线程数量           不能小于0，最大数量 >= 核心线程数量
           参数3：空闲线程最大存活时间     不能小于0
           参数4：时间单位              使用TimeUnit指定
           参数5：任务队列              不能为null
           参数6：创建线程工厂           不能为null
           参数7：任务的拒绝策略         不能为null
        */

        ThreadPoolExecutor pool = new ThreadPoolExecutor(
                3,
                6,
                60,
                TimeUnit.SECONDS,
                new ArrayBlockingQueue<>(3),
                Executors.defaultThreadFactory(),
                new ThreadPoolExecutor.AbortPolicy()
        );
        int count = Runtime.getRuntime().availableProcessors();
        System.out.println(count);
    }
}
